import { Service } from "egg";

/**
 * 处理socket
 */
export default class SocketService extends Service {
  /**
   * 发送到小程序用户的通知
   * @param userId 用户ID
   * @param event 事件名
   * @param params 参数
   */
  async sendMessageToStore(storeId: string, event: string, params: any) {
    const { app, ctx } = this;

    // 向用户发送通知
    app.io.of("/notify").to(`storeId:${storeId}`).emit(event, params);

    ctx.logger.debug(`发送给${storeId}的${event}消息:`, params);
    // console.log(`发送给${socketId}的${event}消息:`, params);
  }
}
